//package com.liwen.service.config;
//
//import com.liwen.service.mq.OrderConsumer;
//import com.weidai.rocketmq.client.SimpleProducer;
//import com.weidai.rocketmq.client.SimplePushConsumer;
//import org.springframework.context.annotation.Bean;
//import org.springf
// ramework.context.annotation.Configuration;
//
//import javax.annotation.Resource;
//
///**
// * @author : li.rui
// * @time : 2017-05-13 14:36
// * @desc : mq配置
// */
//@Configuration
//public class MqConfig extends AppConfig {
//
//    @Resource
//    private OrderConsumer orderConsumer;
//
//    /**
//     * 获取前缀
//     *
//     * @return
//     */
//    @Override
//    protected String prefix() {
//        return "mq.";
//    }
//
//    /**
//     * 生产者
//     *
//     * @return
//     */
//    @Bean
//    public SimpleProducer simpleProducer() {
//        log("rocket.producer.init.start");
//        SimpleProducer producer = new SimpleProducer();
//        producer.setTopic("li-wen");
//        producer.setApplication("li-wen");
//        producer.setNameServerAddress(getStr("rocket.name-server-address"));
//        log("rocket.producer.init.end");
//        return producer;
//    }
//
//    /**
//     * 订单状态变更消费者
//     *
//     * @return
//     */
//    @Bean(name = "orderConsumerListener")
//    public SimplePushConsumer bidStatusConsumer() {
//        log("rocket.consumer.orderConsumer.init.start");
//        SimplePushConsumer consumer = new SimplePushConsumer();
//        consumer.setApplication(getStr("rocket.application"));
//        consumer.setNameServerAddress(getStr("rocket.name-server-address"));
//        consumer.setTopic("liwen-notify");
//        consumer.setMessageListener(orderConsumer);
//        log("rocket.consumer.bidStatusConsumer.init.end");
//        return consumer;
//    }
//}
